Me gustaría convertir mis Observables anidados con el uso de pipe, map, mergeMap, sin embargo, hay condiciones después de las cuales quiero que continúe
observableFunction es un Observable que recorre una matriz, una vez que finaliza, puede continuar para usar los datos manipulados
observableFunction(par1,par2) .subscribe((resp) => { i++; //do stuff, manipulate resp const lastIteration = someArray.length == i; if (lastIteration) { //do stuff observableFunction(par1a, par2a) .subscribe((resp) => { observableHandleFunction(resp) .subscribe((handledData) => { h++; const lastIterationSub = someNestedArray.length == h; //do stuff, manipulate handledData if (lastIterationSub) { console.log("done"); }); }); } });¿Cómo puedo convertirlo para que parezca más fácil de leer usando las funciones de rxjs que están destinadas a usarse en este escenario? ¿Te gusta aplicar condiciones a mergeMap?
observableFunction(par1,par2) .pipe( mergeMap((res1) => { //do stuff CONDITION={ return observableFunction(par1a,par2a) } }), mergeMap((res2) => return observableHandleFunction(res2)) ) .subscribe((res3) => { h++; //do stuff const lastIterationSub = someNestedArray.length == h; if (lastIterationSub) { console.log("done"); } });Con una solución como esta, no funcionará con la condición, lo que generará un error.
En primer lugar, anidar bloques de subscribe siempre es una mala idea.
Si su observableFunction emite valores únicos (en lugar de una matriz completa a la vez) y cuando termina emite un valor completo, puede usar el operador toArray . Asi que:
observableFunction(par1,par2) .pipe(toArray()) // Here you will have an array of items, now you can proceed with something like: observableFunction(par1,par2) .pipe( toArray(), mergeMap(array => { // If neccesary you can do the same here etc }))